package com.hegaoye.service.impl;

import com.hegaoye.mqhandler.KafkaSender;
import com.hegaoye.service.AccountService;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

@Service
public class AccountServiceImpl implements AccountService {
  @Resource private KafkaSender kafkaSender;

  @Override
  public String load() {
    return "provider:hegaoye";
  }

  @Override
  public void save(String order) {
    kafkaSender.sendTopic(order);
  }
}
